package gg.zsw.datasource.demo.kafka;

import gg.zsw.dataframework.pubsub.AbstractObserver;

/**
 * 业务层，只要和这个最终的观察者进行交互就行了
 *
 * @author zhou.sw
 * @Date 2020/6/30 14:34
 */
public class MessageObserver implements AbstractObserver<Message> {

    @Override
    public void update(Message msg) {
        System.out.println("MessageObserver:" + msg.getTime() + "|" + msg.getData());
    }
}
